package com.onec.service.manage.controller;

import com.onec.service.manage.service.kafka.SendFinishService;
import com.onec.service.manage.service.kafka.SendService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping(value = "kafka")
public class KafkaTestController {

    @Autowired
    SendService sendService;

    @Autowired
    SendFinishService sendFinishService;

    @RequestMapping(value = "sentKafkaMessageTest")
    void sentKafkaMessageTest() {
        sendService.sendMsg("测试数据卡夫卡");
        sendFinishService.sendMsg("自定义推送");
    }
}
